package com.example.jobback.websocket.util;

/**
 * @ClassName: RedisStreamConstants
 * @Description: 消息队列常量key
 * @Author: lhb
 * @Date: 2025/9/20
 */

public class RedisStreamConstants {
    /**
     * @Description: 未读消息Stream队列
     * @Author lhb
     * @CreateTime 2025/9/20 21:20
     */
    public static final String UNREAD_MESSAGE_STREAM = "unread_message_stream";

    /**
     * @Description: 消费者组名称
     * @Author lhb
     * @CreateTime 2025/9/20 21:21
     */
    public static final String UNREAD_MESSAGE_CONSUMER_GROUP = "unread_message_group";

    /**
     * @Description: 消费者名称
     * @Author lhb
     * @CreateTime 2025/9/20 21:21
     */
    public static final String UNREAD_MESSAGE_CONSUMER = "unread_consumer";

    /**
     * @Description: 批量处理大小
     * @Author lhb
     * @CreateTime 2025/9/20 21:21
     */
    public static final int BATCH_PROCESS_SIZE = 100;
    
    /**
     * @Description: stream最大承受消息数
     * @Author lhb
     * @CreateTime 2025/9/21 0:32
     */
    public static final long STREAM_MAX_LENGTH =1000;

    /**
     * @Description: stream修剪后保留的数量
     * @Author lhb
     * @CreateTime 2025/9/21 0:45
     */
    public static final long STREAM_REMAIN_LENGTH =500;
}
